package com.zy.ems.common.mq;

import com.taobao.metamorphosis.client.extension.spring.MetaqTemplate;

/**
 * Metaq,用于spring容器中进行配置 <br/>
 * date: 2016年4月25日 下午4:34:09 <br/>
 *
 * @author sunshine
 * @version
 * @since JDK 1.7
 */
public class MetaQInitQBean {

    private MetaqTemplate metaqTemplate;

    public MetaqTemplate getMetaqTemplate() {
        return metaqTemplate;
    }

    public void setMetaqTemplate(MetaqTemplate metaqTemplate) {
        this.metaqTemplate = metaqTemplate;
    }

    /**
     * 在设置完对应的数据源后，需要调用该方法来进行缓存环境的初始化
     */
    public void init() {
        MetaQUtils.getInstance().init(new MetaQUtils.MetaqUtilInitializer() {
            public MetaqTemplate getMetaqTemplate() {
                return metaqTemplate;
            }
        });
    }
}
